package com.mq.core.factory;

import com.mq.core.container.AbstractMessageListenerContainer;
import com.mq.core.endpoint.RedisListenerEndpoint;

public interface RedisListenerContainerFactory<C extends AbstractMessageListenerContainer> {

    C createListenerContainer(RedisListenerEndpoint endpoint);

    /**
     * 最大线程数
     * @return
     */
    int getMaxConsumer();

    /**
     * 死信重试次数
     * @return
     */
    int getRetryTimes();
}
